package com.minshenglife.zanzan.web.weixin.service;

import java.io.InputStream;
import java.util.Date;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import com.minshenglife.zanzan.pub.Config;
import com.minshenglife.zanzan.pub.message.MessageUtil;
import com.minshenglife.zanzan.pub.message.resp.NewsMessage;
import com.minshenglife.zanzan.pub.message.resp.TextMessage;
import com.minshenglife.zanzan.pub.utils.Message;
import com.minshenglife.zanzan.pub.utils.WXKeys;
import com.nationsky.pub.utils.StringUtils;
  
/** 
 * 核心服务类 
 *  
 * @author huodd 
 * @date 2013-05-20 
 */  
@Component
public class CoreService {  
	Logger log = LoggerFactory.getLogger(CoreService.class);
	@Resource
	WXReviewService wxreviewService;
	@Resource
	WXMenuEventService menuEventService;
//	
    /** 
     * 处理微信发来的请求 
     *  
     * @param request 
     * @return 
     */  
    public  String processRequest(HttpServletRequest request) {  
    	log.debug("start processRequest method ===处理微信发来的请求");
        String respMessage = null;  
        try {  
            // 默认返回的文本消息内容  
            String respContent = "";  
  
            // xml请求解析  
            Map<String, String> requestMap = MessageUtil.parseXml(request);  
  
            // 发送方帐号（open_id）  
            String fromUserName = requestMap.get(WXKeys.WX_FROMUSERNAME);  
            // 公众帐号  
            String toUserName = requestMap.get(WXKeys.WX_TOUSERNAME);  
            // 消息类型  
            String msgType = requestMap.get(WXKeys.WX_MSGTYPE);  
  
            // 文本消息  
            if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {  
            	String reqContent=StringUtils.processStrings(requestMap.get(WXKeys.WX_CONTENT));
//                respContent = "您发送的是文本消息！";
            	if(Config.getProperty(reqContent)!=""){
            		respContent = Config.getProperty(reqContent).trim();
            	}else{
	                Message messge=wxreviewService.add(fromUserName,reqContent);
	                respContent= messge.getMsg();
            	}
                TextMessage message = new TextMessage(fromUserName,toUserName,new Date().getTime(),
                		MessageUtil.RESP_MESSAGE_TYPE_TEXT,0,respContent);                  
                respMessage = MessageUtil.textMessageToXml(message);
            }  
            // 图片消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {  
//                respContent = "您发送的是图片消息！";  
            }  
            // 地理位置消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {  
//                respContent = "您发送的是地理位置消息！";  
            }  
            // 链接消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {  
//                respContent = "您发送的是链接消息！";  
            }  
            // 音频消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {  
//                respContent = "您发送的是音频消息！";  
            }  
            // 事件推送  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {  
                // 事件类型  
                String eventType = requestMap.get(WXKeys.WX_EVENT);  
                // 订阅（关注）  
                if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {  
                    respContent = "欢迎您来到民生保险微家！";  
                    TextMessage message = new TextMessage(fromUserName,toUserName,new Date().getTime(),
                    		MessageUtil.RESP_MESSAGE_TYPE_TEXT,0,respContent);                  
                    respMessage = MessageUtil.textMessageToXml(message);
                }  
                // 取消订阅 （关注） 
                else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {  
                    // TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息  
                }  
                // 自定义菜单点击事件  
                else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {  
                	NewsMessage message=new NewsMessage(fromUserName,toUserName,new Date().getTime(),
                    		MessageUtil.RESP_MESSAGE_TYPE_NEWS,0,0,null);
                	String key=requestMap.get(WXKeys.WX_EVENTKEY);
                	log.debug("=========请求菜单的key值："+key);
//                	log.debug("request.getContextPath()"+request.getContextPath());
//                	log.debug("request.getRequestURL()"+request.getRequestURL());
                	message=menuEventService.getEventResult(key,fromUserName,message);
                	
                	respMessage = MessageUtil.newsMessageToXml(message);
                }  
            }else{
            	respContent = "信息发送有误，请确认。";
            	TextMessage message = new TextMessage(fromUserName,toUserName,new Date().getTime(),
                		MessageUtil.RESP_MESSAGE_TYPE_TEXT,0,respContent);                  
                respMessage = MessageUtil.textMessageToXml(message);
            }
            
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
        log.debug("end processRequest method");
        return respMessage;  
    }  
    
    /** 
     * 处理微信发来的请求 
     *  
     * @param request 
     * @return 
     */  
    public  String processRequestOfTest(InputStream inputStream) {  
        String respMessage = null;  
        try {  
            // 默认返回的文本消息内容  
            String respContent = "请求处理异常，请稍候尝试！";  
  
            // xml请求解析  
            Map<String, String> requestMap = MessageUtil.parseXmlByStream(inputStream);  
  
            // 发送方帐号（open_id）  
            String fromUserName = requestMap.get("FromUserName");  
            // 公众帐号  
            String toUserName = requestMap.get("ToUserName");  
            // 消息类型  
            String msgType = requestMap.get("MsgType");  
  
            // 回复文本消息  
            TextMessage textMessage = new TextMessage();  
            textMessage.setToUserName(fromUserName);  
            textMessage.setFromUserName(toUserName);  
            textMessage.setCreateTime(new Date().getTime());  
            textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);  
            textMessage.setFuncFlag(0);  
  
            // 文本消息  
            if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {  
                respContent = "您发送的是文本消息！";
//                Message messge=new UserController().add("@adsfsadf|adsfdsf");
//                respContent= messge.getMsg();
            }  
            // 图片消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {  
                respContent = "您发送的是图片消息！";  
            }  
            // 地理位置消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {  
                respContent = "您发送的是地理位置消息！";  
            }  
            // 链接消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {  
                respContent = "您发送的是链接消息！";  
            }  
            // 音频消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {  
                respContent = "您发送的是音频消息！";  
            }  
            // 事件推送  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {  
                // 事件类型  
                String eventType = requestMap.get("Event");  
                // 订阅  
                if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {  
                    respContent = "谢谢您的关注！";  
                }  
                // 取消订阅  
                else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {  
                    // TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息  
                }  
                // 自定义菜单点击事件  
                else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {  
                    // TODO 自定义菜单权没有开放，暂不处理该类消息
                	
                }  
            }else{
            	respContent = "信息发送有误，请确认。";
            }
  
            textMessage.setContent(respContent);
            respMessage = MessageUtil.textMessageToXml(textMessage);
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
  
        return respMessage;  
    }  
}  